package com.boarsoft.boar.message.service.impl;

import com.boarsoft.boar.message.biz.RecipientQueueBiz;
import com.boarsoft.boar.message.entity.RecipientQueueEntity;
import org.springframework.beans.factory.annotation.Autowired;

public class RecipientQueueMonitorImpl extends AbstractQueueMonitorImpl {
	public RecipientQueueMonitorImpl() {
		type = "recipient";
	}

	@Autowired
	protected RecipientQueueBiz recipientQueueBiz;

	protected Object gather(String queueId) {
		RecipientQueueEntity rq =recipientQueueBiz.get(queueId);
		return brokerAdapter.getMessageBroker(rq.getBroker()).statRecipientQueue(rq.getCode());
	}
}
